package cn.gwm.flink.streaming.test;

import cn.gwm.flink.streaming.business.ModuleConfData;
import cn.gwm.flink.streaming.config.GlobalConfigSingleton;
import org.apache.flink.api.java.tuple.Tuple2;

public class ConfigUpdater {

    public static void main(String[] args) throws InterruptedException {
        GlobalConfigSingleton grobalConfig = GlobalConfigSingleton.getInstance();
        ModuleConfData conf = grobalConfig.getGlobalModuleConfigData();
//                grobalConfig.init();
        System.out.printf("list" + grobalConfig.getGlobalModuleConfigData() + "\n");
        System.out.printf("-conf-" + conf.getConfigByVehicleType("ES13"));
        Tuple2<Boolean, Boolean> a = conf.getConfigByReserveChargeType("ES16");
        System.out.printf("a =" + a);


    }

}